5-客户端推送 PUSH

接收客户端的PUSH请求，请求处理器走的SPI机制，业务实现由SPI扩展实现；

1 2	//ConnectionServer#init() messageDispatcher.register(Command.PUSH, PushHandlerFactory::create);

public interface PushHandlerFactory extends Factory<MessageHandler> {
    static MessageHandler create() {
        return SpiLoader.load(PushHandlerFactory.class).get();
    }
}

@Spi(order = 1)
public final class ClientPushHandler extends BaseMessageHandler<PushMessage> implements PushHandlerFactory {
    @Override
    public PushMessage decode(Packet packet, Connection connection) {
        return new PushMessage(packet, connection);
    }
    @Override
    public void handle(PushMessage message) {
        Logs.PUSH.info("receive client push message={}", message);

        if (message.autoAck()) {
            AckMessage.from(message).sendRaw();
            Logs.PUSH.info("send ack for push message={}", message);
        }
        //biz code write here
    }
    @Override
    public MessageHandler get() {
        return this;
    }
}

接入服务文章目录: